package sql.d20241107;

import org.apache.flink.table.functions.TableFunction; /**
 * 定义表函数
 * 将一行按照逗号分割转换为多行
 */
public class splitRow extends TableFunction<String> {

  public void eval(String row) {
    if (row != null) {
      for (String s : row.split(",")) {
        collect(s);
      }
    }
  }
}
